package com.ot.flink.cdc.dto;

import lombok.Data;

import java.io.Serializable;
import java.util.Map;

/**
 * insert update delete 数据
 * @author: admin
 * @date: 2024/4/21
 * @since JDK1.8 version: 1.0.0
 */
@Data
public class TableLogDto implements Serializable {

    /** serial id */
    private static final long serialVersionUID = 1L;

    private String database;

    private String schema;

    private String table;

    private String op;

    /** 当前内容 */
    private Map<String, Object> current;

    /** 更新前的内容 */
    private Map<String, Object> before;

    /** 更新后的内容 */
    private Map<String, Object> after;

    /** 更新时间戳 */
    private Long ts;
}
